#ifndef DATARINGCONSUMETHREAD_HPP
#define DATARINGCONSUMETHREAD_HPP
#include <epicsThread.h>
#include <epicsEvent.h>
#include "epicsRingBytes.h"
#include "EventData.hpp"
#define RecieveBufferSize 1024000
#define DataLengthEvery 128
//#define DEBUG
class DataRingConsumeThread: public epicsThreadRunable {
public:
	DataRingConsumeThread(TcpSocketDataInfo *);
	~DataRingConsumeThread();
	void run();
	void printBuffer();
private:
	TcpSocketDataInfo *pTcpSocketDataInfo;
	int pulseCount;
	int errorCount;

};


#endif